package com.foreveross.taskservice.common.mq;

import com.foreveross.taskservice.common.CacheDataSpace;
import com.foreveross.taskservice.common.GlobalsConst;

/**
 * 一个队列名字的build
 * 对于区分级别的渠道以及数据空间的划分需要一个统一的build
 * 后期优化
 * @author Administrator
 *
 */
public class QueueNameBuild {
	/**
	 * 生成一个任务队列名称
	 * @param space
	 * @param channelId
	 * @return
	 */
	public static String buildTaskQueueName(CacheDataSpace space,long channelId){
		return GlobalsConst.MQ_CRAWLTASKQUEUE_PREFIX+GlobalsConst.SEPARATOR_UNDERLINE
				+space.getSpace()+GlobalsConst.SEPARATOR_UNDERLINE+channelId;
	}
	
	/**
	 * 生成一个回滚队列名称
	 * @param space
	 * @return
	 */
	public static String buildRollQueueName(CacheDataSpace space){
		return GlobalsConst.MQ_CRAWLTASKROLLBACKQUEUE_PREFIX+GlobalsConst.SEPARATOR_UNDERLINE
				+space.getSpace();
	}
}
